package base

interface IPipeStream<T> {

    /**
     * open a stream
     */
    fun open()

    /**
     * write data, get the write content by T.toString
     */
    fun write(list: MutableList<T>)

    /**
     * close the stream
     */
    fun close()
}